d0460ff23c3ce3dea35f616c5c7a242d121edf27,core/client/src/main/java/alluxio/client/netty/NettyUnderFileSystemFileWriter.java,NettyUnderFileSystemFileWriter,write,#InetSocketAddress#number#number#number[]#number#number#,62
Before Change
try {
channel = BlockStoreContext.acquireNettyChannel(address, mClientBootstrap);
listener = new SingleResponseListener();
((ClientHandler) channel.pipeline().last()).addListener(listener);
ChannelFuture channelFuture = channel.writeAndFlush(
new RPCFileWriteRequest(ufsFileId, fileOffset, length,
new DataByteArrayChannel(source, offset, length))).sync();
After Change
try {
channel = BlockStoreContext.acquireNettyChannel(address, mClientBootstrap);
listener = new SingleResponseListener();
channel.pipeline().get(ClientHandler.class).addListener(listener);
ChannelFuture channelFuture = channel.writeAndFlush(
new RPCFileWriteRequest(ufsFileId, fileOffset, length,
new DataByteArrayChannel(source, offset, length))).sync();